package com.bwie.config;

import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

/**
 * @Author: lrz
 * @Date: 2024/11/4 14:38
 * @Description:
 **/
@Configuration
public class KfkConfig {

    @Bean
    public NewTopic createTopic(){
        return new NewTopic("test_topic", 3, (short) 1);
    }

}
